// 引入mysql依赖
var mysql = require("mysql")

/**
 * 创建数据库连接池
 */
var pool = mysql.createPool({
  /* connectionLimit: 10, // 设置连接个数 */
  host: "localhost",
  user: "root",
  password: "123456",
  port: "3306",
  database: "cmms"
  /* multipleStatements: true // 添加支持多条查询语句 */
})

/**
 * @param {*} sql 查询语句
 * @param {*} params 查询字段
 * @param {*} callback 回调函数
 */
var querys = function(sql, params, callback) {
  pool.getConnection(function(err, conn) {
    if (err) throw err
    conn.query(sql, params, function(error, results, fields) {
      callback(error, results, fields)
      conn.release()
      if (error) throw error
    })
  })
}

module.exports = querys